from com.zsw.config.LocalSparkConfig import LocalSparkConfig

spark_config = LocalSparkConfig()
ss = spark_config.get_spark_session() # sparkSession 简写ss SparkSession 是从 Spark 2.0 开始引入的新入口点，它封装了 SparkContext、SQLContext 和 HiveContext 的功能。
print(ss.version) #3.5.5

rdd = ss.read.text("E:/pythonProject/pyspark-demo/pythonProject1/com/zsw/hello.txt")
print(rdd.collect())
rdd.show()




# 停止sparkSession对象的运行
ss.stop()
